﻿using Microsoft.Extensions.DependencyInjection;
using Msung.Core.Kafka.Integration;

namespace Msung.Core.Kafka
{
    public interface IKafkaConsumerBuilder
    {
        IServiceCollection Services { get; }

        IKafkaConsumerBuilder AddListener(Action<IServiceProvider, RecieveResult> onMessageRecieved);
    }
}
